package com.itcast.bulls.stock.pending.config;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.SubscribableChannel;

@Configuration
@EnableBinding({RocketMqConsumeConfiguration.QueueSource.class })
public class RocketMqConsumeConfiguration {

    public interface QueueSource {
        @Input("quote")
        SubscribableChannel quote();
    }
}
